# -*- coding: utf-8 -*-
# @Time    : 2019/10/21 21:29
# @Author  : LiHaowen
# @Email   : lihaowen2017@163.com
# @File    : socket_server.py

import socket
import threading

server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)  # 指定类型， 类型对应的协议
server.bind(('0.0.0.0', 8000))  # 协议，地址，端口 tuple 绑定到0.0.0.0 是自动搜网卡地址
server.listen()  # server用来监听


def handle_sock(sock, addr):
    while True:
        data = sock.recv(1024)  # data返回的是bytes类型
        res = data.decode("utf8")
        print(res)
        if res == "bye" or res == "exit":
            break
        re_data = input()
        sock.send(re_data.encode("utf8"))
    sock.close()


# print(sock)
# print(addr)

# 获取从客户端发送的数据
# 一次获取1k的数据
while True:
    sock, addr = server.accept()  # 接收到连接请求得到sock和address sock 套接字对象 用来发送
    # 用线程去处理新接收到的连接(用户)
    client_thread = threading.Thread(target=handle_sock, args=(sock, addr))
    client_thread.start()

    # data = sock.recv(1024)  # data返回的是bytes类型
    # print(data.decode("utf8"))
    # re_data = input()
    # sock.send(re_data.encode("utf8"))
    # sock.send("hello {}".format(data.decode("utf8")).encode("utf8"))  # socket 只能发送bytes类型
    # server.close()
    # sock.close()
